package com.itcam.kafka.config;

import org.apache.kafka.clients.admin.NewTopic;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.kafka.config.TopicBuilder;

/**
 * Kafka 配置类，用于创建 Kafka 主题的 Bean
 */
@Configuration
public class KafkaConfig {

    /**
     * 创建一个名为 "topic-01" 的 Kafka 主题的 Bean
     *
     * @return 一个新的 Kafka 主题对象
     */
    @Bean
    public NewTopic springTestTopic() {
        // 使用 TopicBuilder 构建一个新的 Kafka 主题
        return TopicBuilder
                // 设置主题名称为 "topic-01"
                .name("topic-01")
                // 设置主题的分区数为 3
                .partitions(3)
                // 设置主题的副本数为 3
                .replicas(3)
                // 构建并返回主题对象
                .build();
    }
}
